/**
 * @author zhounan 
 * @date 2024年5月20日
 * @version V1.0
 */
package org.zn.etl.service;

import java.util.List;
import java.util.Map;

import org.zn.etl.job.context.JobExecInstanceContext;
import org.zn.etl.job.entity.po.JobExecInstancePo;

/**
 * @author zhounan 
 * @date 2024年5月20日
 * @version V1.0
 */
public interface EtlExecuteService {
	
	/**
	 * 执行job
	 * @param job
	 */
	public void executeJob(JobExecInstanceContext ejei)throws Exception;
	
	public JobExecInstanceContext executeJob(String jobName ,Map<String, Object> execParam) throws Exception;
	
	public void addContext(Map<String, Object> map) ;
	
	public Map<String, Object> getGlobalContext() ;
	
	public void executeGroup(String group,Map<String, Object> execParam);

	
	/**
	 * 
	 * @param jobName
	 * @param startTime
	 * @param endTime
	 * @param status
	 * @return
	 */
	public List<JobExecInstancePo> queryInstanceList(Long jobId, String startTime, String endTime, String status);

}
